package com.bjtu.boatmq.client.consumer;

public class ConsumerThread implements Runnable {
	
	private String records;
	
	public ConsumerThread(String router_data) {
		this.records = router_data;
	}

	public void run() {
		
			 System.out.println("got mesage from router: "+this.records);
	}
}
